const mysql = require('mysql')
const db_config = require('../config/db.config')

// 连接数据库,使用mysql连接池连接方式
const sqlConnect = (sql,sqlArr,callback) => {
        var pool = mysql.createPool(db_config)
        console.log('开始连接数据库!!!')
        pool.getConnection((err, conn)  => {
            if (err) {
                console.log('连接失败')
                return
            }
            // 事件驱动回调
            conn.query(sql,sqlArr,callback)
            // 释放连接
            conn.release()
        })
}

module.exports = {
    sqlConnect
}